#pragma once
#include <map>
//#include "threadlock.h"
#include "threadsafevector.h"
#include "EventDef.h"
#include "EventListenerGroup.h"
#include "sharedqueue.h"
#include "threadsafemap.h"
#include "Lib.MatlabStrategyEngineDef.h"
#include "threadtask.h"
USING_LIBSPACE


class ENGINE_API CEventReactor : public ThreadTask
{
public:
	CEventReactor(void);
	~CEventReactor(void);
	bool Start();
	

	
	virtual int svc();

#pragma warning(disable : 4251)
	blockabledqueue<IEvent> m_eventsqueue;
};
